package pers.qianyu.service;

import com.alibaba.fastjson.*;
import lombok.extern.slf4j.*;
import org.apache.rocketmq.spring.annotation.*;
import org.apache.rocketmq.spring.core.*;
import org.springframework.stereotype.*;
import pers.qianyu.domain.*;

@Slf4j
@Service
@RocketMQMessageListener(consumerGroup = "tx-topic-group", topic = "tx-topic")
public class SmsService implements RocketMQListener<Order> {
    @Override
    public void onMessage(Order order) {
        log.info("收到一条信息：{}", JSON.toJSONString(order));
    }
}
